//package com.cuijq.dubbo.common;
//
//
//import io.netty.buffer.ByteBuf;
//import io.netty.channel.ChannelHandlerContext;
//import io.netty.handler.codec.ByteToMessageDecoder;
//
//import java.util.List;
//
//public class RpcDecoder extends ByteToMessageDecoder {
//    @Override
//    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
//        if (in.readableBytes() < 4) {
//            return;
//        }
//        in.markReaderIndex();
//        int length = in.readInt();
//        if (in.readableBytes() < length) {
//            in.resetReaderIndex();
//            return;
//        }
//        byte[] bytes = new byte[length];
//        in.readBytes(bytes);
//        String json = new String(bytes);
//        System.out.println(json);
//        RpcResponse response = JsonUtil.fromJson(json, RpcResponse.class);
//        out.add(response);
//    }
//}
